package maxminSalary;import org.apache.hadoop.io.LongWritable;import org.apache.hadoop.io.Text;import org.apache.hadoop.mapreduce.Mapper;import java.io.IOException;public class MaxMinSalaryMapper extends Mapper<LongWritable, Text, Text, Text> {    private int flag = 1 ;    @Override    protected void map(LongWritable key, Text value, Context context) throws IOException, InterruptedException {        //用一个flag变量来去除处理第一行        if(flag == 1){            flag ++ ;            return;        }        // 将一行数据按逗号分割成数组        String[] dataArray = value.toString().split(",");            String companyName = dataArray[0];            String salaryStr = dataArray[6];            //将公司名和公司对应的字符串传给reduce            context.write(new Text(companyName), new Text(salaryStr));    }}